package pipeline;

import java.sql.ResultSet;

/**
 * Created by Administrator on 2017/3/17.
 */
public class DataSyncTask implements Runnable {


    @Override
    public void run() {
        ResultSet rs = null ;
        //SimplePipeline<RecordSaveTask,String> pipeline = buildPipeline();


    }

    private static class RecordSaveTask {
        public final Record[] records;
        public final int targetFileIndex;
        public final String recordDay;

        public RecordSaveTask(Record[] records, int targetFileIndex, String recordDay) {
            this.records = records;
            this.targetFileIndex = targetFileIndex;
            this.recordDay = recordDay;
        }
    }
}
